//package com.study.reactor;
//
//import reactor.core.publisher.FluxProcessor;
//import reactor.core.publisher.Mono;
//import reactor.core.publisher.UnicastProcessor;
//
///**
// * @author yuantongqin
// * desc:
// * 2020-11-04
// */
//public class ReactorApp {
//
//    public static void main(String[] args) {
//
////        aa();
//        bb();
//    }
//
//    public static void aa(){
//
////        上例代码中生成数据流和注册/执行 lambda 是在同一线程中，但也可以在不同线程中。
//        // 1. 创建
//        FluxProcessor<Integer,Integer> publisher = UnicastProcessor.create();
//        // 3. 上例中 lambda 响应了该事件，输出了相应的信息
//        publisher.doOnNext(integer -> System.out.println(Thread.currentThread().getName()+"=="+integer)).subscribe();
//
//        // 2. publisher 产生了数据流 (1,2)，并且传播给了 OnNext 事件,
//        publisher.onNext(1);
//        publisher.onNext(2);
//
//        System.out.println(Thread.currentThread().getName());
//    }
//
//    public static void bb(){
//        Mono.just("hello").filter(info->info.equalsIgnoreCase("hello")).subscribe();
////        Consumer<MonoSink<String>> consumer = new Consumer<MonoSink<String>>() {
////            @Override
////            public void accept(MonoSink<String> monoSink) {
////
////            }
////        };
////        Mono.create(consumer);
//
////        Mono.zip()
//
//    }
//}
